746f320a3ae5cdb8fcec8db095ced7a5ffed3127,rxnetty-examples/src/main/java/io/reactivex/netty/examples/tcp/proxy/ProxyClient.java,ProxyClient,main,#String[]#,34
Before Change
SocketAddress serverAddress = getServerAddress(ProxyServer.class, args);
/*Create a new client for the server address*/
TcpClient.<ByteBuf, ByteBuf>newClient(serverAddress)
/*Create a new connection request, each subscription creates a new connection*/
.createConnectionRequest()
/*Upon successful connection, write "Hello World" and listen to input*/
.flatMap(connection ->
After Change
SocketAddress serverAddress = getServerAddress(ProxyServer.class, args);
/*Create a new client for the server address*/
TcpClient.<ByteBuf, ByteBuf>newClient(serverAddress)
.enableWireLogging(LogLevel.DEBUG)
/*Create a new connection request, each subscription creates a new connection*/
.createConnectionRequest()
/*Upon successful connection, write "Hello World" and listen to input*/
.flatMap(connection ->